package com.lry.consumer;

public interface MqConsumer {

    void start();

    void shutdown();

    void subscribe(String topic,String expr);

    void subscribe(String topic);

    void registerMessageListener(MessageListener messageListener);

}
